//package com.dingwen.stusprboomon.listener;
//
//import com.mongodb.client.model.changestream.ChangeStreamDocument;
//import org.bson.Document;
//import org.springframework.data.mongodb.core.messaging.Message;
//import org.springframework.data.mongodb.core.messaging.MessageListener;
//import org.springframework.stereotype.Component;
//
///**
// * mongo 文档监听器
// *
// * @author dingwen
// * 2021.06.28 13:54
// */
//@Component
//public class DocumentMessageListener implements MessageListener<ChangeStreamDocument<Document>,Document> {
//    @Override
//    public void onMessage(Message<ChangeStreamDocument<Document>, Document> message) {
//        //TODO 日志 数据同步
//
//        System.out.println("message.getProperties() = " + message.getProperties());
//        System.out.println("message.getBody() = " + message.getBody());
//        System.out.println("message.getRaw() = " + message.getRaw());
//    }
//}
